package io.kiki.task.server.job.task.client;

import io.kiki.task.client.model.StopJobDTO;
import io.kiki.task.client.model.request.DispatchJobRequest;
import io.kiki.task.common.core.model.Result;
import io.kiki.task.server.common.rpc.client.annotation.Body;
import io.kiki.task.server.common.rpc.client.annotation.Path;

import static io.kiki.task.common.core.constant.SystemConstants.HTTP_PATH.JOB_DISPATCH;
import static io.kiki.task.common.core.constant.SystemConstants.HTTP_PATH.JOB_STOP;

/**
 * 调用客户端接口
 */
public interface JobRpcClient {

    @Path(value = JOB_STOP)
    Result<Boolean> stop(@Body StopJobDTO stopJobDTO);

    @Path(value = JOB_DISPATCH)
    Result<Boolean> dispatch(@Body DispatchJobRequest dispatchJobRequest);

}
